package com.bjtu.boatmq.client.consumer;

public class ConsumerMain {
	
	public static void main(String[] args) {
		
		Consumer consumer = new Consumer();
		try {
			consumer.start();
			Thread.sleep(2000);
			}
		catch (InterruptedException e) {
				e.printStackTrace();
				} 
		finally {
			consumer.shutdown();
			}
	}
}
